package com.codejiwei.sample

import org.apache.flink.runtime.state.filesystem.FsStateBackend
import org.apache.flink.streaming.api.CheckpointingMode
import org.apache.flink.streaming.api.scala.StreamExecutionEnvironment

/**
 * Author: jiwei01
 * Date: 2022/8/25 10:59
 * Package: com.codejiwei.sample
 * Description:
 */
object TestFlinkWithCheckpoint extends App {
  private val env: StreamExecutionEnvironment = StreamExecutionEnvironment.getExecutionEnvironment
  env.setParallelism(2)
  env.enableCheckpointing(5000, CheckpointingMode.EXACTLY_ONCE)
//  env.setStateBackend(new FsStateBackend(""))
}
